package com.burges.net.dataStream.codeRuler.dataInputStream.datasources

import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _}

/**
  * 创建人    BurgessLee 
  * 创建时间   2020/1/26 
  * 描述     集合类数据源
  */
object CollectionDataSourceDemo {

	def main(args: Array[String]): Unit = {
		val env = StreamExecutionEnvironment.getExecutionEnvironment

		//通过fromElements从元素集合创建数据集
		val datas = env.fromElements(Tuple2(1L,3L), Tuple2(1L,5L), Tuple2(1L,7L))
		datas.print()

	}

}
